const mysql = require('mysql2');
// 创建 mysql 连接池资源
var pool = mysql.createPool({
	host: 'rm-bp1wm4r2nx20li4926o.mysql.rds.aliyuncs.com',
	user: 'wisher',
	password: 'Wisher123',

	// host: 'localhost',
	// user: 'user',
	// password: '1246295951aA',

	database: 'video',
	charset: "utf8mb4",
	waitForConnections: true,
	connectionLimit: 4000, //单次可创建最大连接数
	queueLimit: 0 //连接池的最大请求数，从getConnection方法前依次排队。设置为0将没有限制
});

const promisePool = pool.promise();

async function query2(sql, arr) {
	//建立链接
	return promisePool.query(sql, arr);
};


function query(sql, arr, callback) {
	//建立链接
	// pool.getConnection(function(err, connection) {
	// 	if (err) {
	// 		throw err;
	// 		return;
	// 	}
	// 	connection.query(sql, arr, function(error, results, fields) {
	// 		//将链接释放,防止重复使用是没占用.
	// 		connection.release();
	// 		if (error) throw error;
	// 		//执行回调函数，将数据返回
	// 		callback && callback(results, fields);
	// 	});
	// });

	pool.execute(sql, arr, function(err, rows, fields) {
		if (err) throw err;
		callback && callback(rows, fields);
	});

};


module.exports = {
	query,
	query2
}